cd64f2c390344894eb5b5437c9a19cbb281f5f50,src/spade/storage/kafka/ServerWriter.java,ServerWriter,writeRecord,#GenericContainer#,89

Before Change


		long currentTime = System.currentTimeMillis();
    	if((currentTime - statsLastReportedTime) >= reportStatsAfterEveryMs){
    		statsLastReportedTime = currentTime;
    		printStats();
    	}
		
		/**

After Change


        ProducerRecord<String, GenericContainer> record = new ProducerRecord<>(kafkaTopic, genericContainer);
        serverWriter.send(record); //asynchronous send
        
        if(reportingEnabled){
        	recordCount++;
			long currentTime = System.currentTimeMillis();
	    	if((currentTime - lastReportedTime) >= reportEveryMs){
	    		printStats();
	    		lastReportedTime = currentTime;
	    		lastReportedRecordCount = recordCount;
	    	}